//package com.sy.mq.config;
//
//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.stereotype.Component;
//
//@Component
//public class DirectReceiver {
//
//    //监听直连队列消息
//    @RabbitHandler
//    @RabbitListener(queues = "myDirectQueue")
//    public void process(String msg) {
//        System.out.println("监听到的消息：------------>" + msg);
//    }
//
//    //监听扇形队列消息A
//    @RabbitHandler
//    @RabbitListener(queues = "fanoutQueueA")
//    public void processA(String msg) {
//        System.out.println("fanoutQueueA-------->" + msg);
//    }
//
//    //监听扇形队列消息B
//    @RabbitHandler
//    @RabbitListener(queues = "fanoutQueueB")
//    public void processB(String msg) {
//        System.out.println("fanoutQueueB-------->" + msg);
//    }
//
//    //监听扇形队列消息C
//    @RabbitHandler
//    @RabbitListener(queues = "fanoutQueueC")
//    public void processC(String msg) {
//        System.out.println("fanoutQueueC-------->" + msg);
//    }
//
//    @RabbitHandler
//    @RabbitListener(queues = "myTopicQueue_01")
//    public void process_01(String msg) {
//        System.out.println("myTopicQueue_01-------->" + msg);
//    }
//
//    @RabbitHandler
//    @RabbitListener(queues = "myTopicQueue_02")
//    public void process_02(String msg) {
//        System.out.println("myTopicQueue_02-------->" + msg);
//    }
//}
